package cn.matrix42.potoo.io.transformation;

import cn.matrix42.potoo.io.operator.Operator;

public abstract class Transformation<O extends Operator> {

    private O operator;
    private int parallelism = 1;

    public Transformation(O operator) {
        this.operator = operator;
    }

    public int getParallelism() {
        return parallelism;
    }

    public void setParallelism(int parallelism) {
        this.parallelism = parallelism;
    }
}
